package felix.rule.api;

import felix.rule.data.msg.EngineMsg;

import java.util.concurrent.ExecutionException;

public interface TNode {

    void init(TContext ctx, TNodeConfiguration configuration) throws TNodeException;

    void onMsg(TContext ctx, EngineMsg msg) throws ExecutionException, InterruptedException, TNodeException;

    void destroy();

}
